Skip to content

feat: Allow consumers to start from a specified offset#585

Closed
Waddas wants to merge 7 commits intoFarfetch:masterfrom
Waddas:feature/Consumer-ManualAssignPartitionsOffset
Closed

feat: Allow consumers to start from a specified offset#585
Waddas wants to merge 7 commits intoFarfetch:masterfrom
Waddas:feature/Consumer-ManualAssignPartitionsOffset

Conversation

@Waddas
Copy link
Copy Markdown

@Waddas Waddas commented Jul 30, 2024

Description

Implemented ManualAssignPartitionOffsets to allow consumers to start consuming from a specified offset.

Fixes #584

How Has This Been Tested?

I've added ManualAssignPartitionOffsetsTest into the integration test suite. This uses the bootstrapped service provider to place 10 messages into a topic initially. It then creates a new service provider with a consumer to start at offset 5. The test verifies that the consumer only consumes messages at offsets 5 - 9.
I've added a ServiceProviderHelper to aid in the creation of the provider and refactored the GlobalEventTests to reduce code duplication.

Manual tests to verify consumers are starting from the specified offsets.

Checklist

  • My code follows the style guidelines of this project
  • I have performed a self-review of my own code
  • I have added tests to cover my changes
  • I have made corresponding changes to the documentation

Notes

I had to convert SaslOauthbearerMethod.cs to a file-scoped namespace or the solution would not build. Happy to revert this if needed.

Disclaimer

By sending us your contributions, you are agreeing that your contribution is made subject to the terms of our Contributor Ownership Statement

@Waddas Waddas changed the title feat: feat: Allow consumers to start from a specified offset Jul 30, 2024
Comment thread .github/workflows/build.yml
Comment thread .github/workflows/publish.yml
Comment thread tests/KafkaFlow.IntegrationTests/Core/Handlers/MessageStorage.cs Outdated
Comment thread tests/KafkaFlow.IntegrationTests/Core/Handlers/MessageStorage.cs
@Waddas Waddas requested a review from joelfoliveira August 29, 2024 18:00
@Waddas Waddas closed this by deleting the head repository Jan 1, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Development

Successfully merging this pull request may close these issues.

[Feature Request]: Allow consumers to start consuming from specified offset

6 participants